package online.heycm.platform.rocketmq.consumer;

import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @author heycm
 * @since 2023/12/9 14:57
 */
@Configuration
@ConditionalOnBean(EventConsumer.class)
public class EventConsumerAutoConfiguration {

    @Bean
    public ClusterListener clusterListener() {
        return new ClusterListener();
    }

    @Bean
    public BroadcastListener broadcastListener() {
        return new BroadcastListener();
    }

    @Bean
    public OrderlyListener orderlyListener() {
        return new OrderlyListener();
    }

}
